package com.smarthome.api.ipc;

// public class IpcServerMainProcessor implements ApplicationListener<ContextRefreshedEvent> {
//
// private static ResourceBundle resource = ResourceBundle.getBundle("conf/ipc-config");
// @Resource
// private IpcServerHandler ipcServerHandler;
//
// @Override
// public void onApplicationEvent(ContextRefreshedEvent event) {
// if (event.getApplicationContext().getParent() == null) {
// int port = Integer.parseInt(resource.getString("ipc.base.port"));
// // 监听即将到来的TCP连接，建立监控器
// IoAcceptor acceptor = new NioSocketAcceptor();
// // 设置拦截器
// acceptor.getFilterChain().addLast("logger", new LoggingFilter());
// acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));
// // 设置处理类
// acceptor.setHandler(ipcServerHandler);
// // 设置配置
// acceptor.getSessionConfig().setReadBufferSize(2048);
// acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
// // 绑定的监听端口，可多次绑定，也可同时绑定多个。
// try {
// acceptor.bind(new InetSocketAddress(port));
// } catch (IOException e) {
// e.printStackTrace();
// }
// System.out.println("服务端启动成功......端口号为： " + port);
// }
// }
// }